package com.test.rxjavaImp;

//被观察者的顶层接口
public interface ObservableSource {
    /**
     * addObserver
     * @param observer
     */
    void subscribe(Observer observer);
}
